57a15f62db022f389eaa93e6586f09242422d0a0,tests/test_apps/matviewbenchmark/src/matviewbenchmark/MaterializedViewBenchmark.java,MaterializedViewBenchmark,runHalf,#boolean#FileWriter#,373
Before Change
benchmarkStartTS = System.currentTimeMillis();
schedulePeriodicStats();
System.out.println("\n\nUpdating grouping column in table " + systemStr + " materialized view...\n");
if (config.group > 0) {
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_group_id_update",
grp,
i);
if (grp == (config.group + 1)) {
grp = 2;
} else {
grp++;
}
}
} else {
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_group_id_update",
(i + 1),
i);
}
}
timer.cancel();
client.drain();
if ((config.statsfile == null) || (config.statsfile.length() == 0)) {
printResults(procStr + "_group_id_update");
} else {
printResults(procStr + "_group_id_update", fw, "Update Group " + csvStr + " MV");
}
System.out.print(HORIZONTAL_RULE);
benchmarkStartTS = System.currentTimeMillis();
schedulePeriodicStats();
System.out.println("\n\nUpdating aggregated column in table " + systemStr + " materialized view...\n");
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_value_update",
(i + 1),
i);
}
timer.cancel();
client.drain();
if ((config.statsfile == null) || (config.statsfile.length() == 0)) {
After Change
}
System.out.print(HORIZONTAL_RULE);
if (!matView.equals("minMatView")) {
// grp is initialized to 2 for updating the grouping column to (grouping column = grouping column + 1)
grp = 2;
fullStatsContext.fetchAndResetBaseline();
periodicStatsContext.fetchAndResetBaseline();
benchmarkStartTS = System.currentTimeMillis();
schedulePeriodicStats();
System.out.println("\n\nUpdating grouping column in table " + systemStr + " materialized view...\n");
if (config.group > 0) {
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_group_id_update",
grp,
i);
if (grp == (config.group + 1)) {
grp = 2;
} else {
grp++;
}
}
} else {
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_group_id_update",
(i + 1),
i);
}
}
timer.cancel();
client.drain();
if ((config.statsfile == null) || (config.statsfile.length() == 0)) {
printResults(procStr + "_group_id_update");
} else {
printResults(procStr + "_group_id_update", fw, "Update Group " + csvStr + " MV");
}
System.out.print(HORIZONTAL_RULE);
fullStatsContext.fetchAndResetBaseline();
periodicStatsContext.fetchAndResetBaseline();
benchmarkStartTS = System.currentTimeMillis();
schedulePeriodicStats();
System.out.println("\n\nUpdating aggregated column in table " + systemStr + " materialized view...\n");
for (int i=0; i<config.txn; i++){
client.callProcedure(new NullCallback(),
procStr + "_value_update",
(i + 1),
i);
}
timer.cancel();
client.drain();
if ((config.statsfile == null) || (config.statsfile.length() == 0)) {